9e3c97882d32856f1e1bace5382b78a6203191c1,fcrepo-reindexing/src/main/java/org/fcrepo/camel/reindexing/RestProcessor.java,RestProcessor,process,#Exchange#,57
Before Change
final Message in = exchange.getIn();
final String path = in.getHeader(Exchange.HTTP_PATH, "", String.class);
final String contentType = in.getHeader(Exchange.CONTENT_TYPE, "", String.class);
final String body = in.getBody(String.class);
final Set<String> endpoints = new HashSet<>();
for (final String s : in.getHeader(ReindexingHeaders.RECIPIENTS, "", String.class).split(",")) {
endpoints.add(s.trim());
}
After Change
final String body = in.getBody(String.class);
final Set<String> endpoints = new HashSet<>();
for (final String s : in.getHeader(REINDEXING_RECIPIENTS, "", String.class).split(",")) {
endpoints.add(s.trim());
}